package com.dmzc.stage2.chapter15;

import java.util.concurrent.TimeUnit;

public class TestObservableThread {
    public static void main(String[] args) {
        Observable observableThread=new ObservableThread<String>(()->{
            try{
                TimeUnit.SECONDS.sleep(10);
            }catch (InterruptedException e){
                e.printStackTrace();
            }
            System.out.println("finish done.");
            return "Test ObservableThread";
        });
    }
}
